from .celery01 import app

from celery.result import AsyncResult


def get_result(task_id):
    res = AsyncResult(id=task_id, app=app)
    if res.successful():
        result = res.get()
        print(result)
        return result
    elif res.failed():
        print("任务失败")
        return '任务失败'
    elif res.status == 'PENDING':
        print("任务等待中执行")
        return '任务等待中执行'
    elif res.status == 'RETRY':
        print("任务异常后正在重试")
        return '任务异常后正在重试'
    elif res.status == 'STARTED':
        print("任务已经开始执行")
        return '任务已经开始执行'
